package top.codedance.iotp.server.net.handle.util;

import top.codedance.iotp.common.entity.CommonEntity;
import top.codedance.iotp.server.net.handle.exception.RequestClientTimeoutException;
import cd.io.netty.channel.Channel;

public interface SyncRequestService {

    /**
     * 异步发送
     * @param channel
     * @param commonEntity
     * @return
     */
    CommonEntity sendSyncMsg(Channel channel, CommonEntity commonEntity) throws RequestClientTimeoutException;

    /**
     * 回复通知
     * @param commonEntity
     */
    void ackSyncMsg(CommonEntity commonEntity);
}
